//package com.kun.framework.queue.core;
//
//import com.kun.framework.core.config.DefaultAbstractInitialize;
//import com.kun.framework.queue.dto.KunMessage;
//
///**
// * 坤坤消息队列服务
// *
// * @author gzc
// * @since 2024/8/21
// **/
//public class MessageQueueService extends DefaultAbstractInitialize {
//    private static DefaultProducer defaultProducer;
//
//    @Override
//    public void init() {
//
//    }
//
//    @Override
//    public void startupBefore() {
//        defaultProducer = new DefaultProducer();
//    }
//
//    public static void send(KunMessage message) {
//        OperationProgressController operationProgressController = StageSingletonFactory.getInstance(OperationProgressController.class);
//        operationProgressController.put((String) message.getMessage());
//        defaultProducer.publish(message);
//    }
//
//    public static void asyncSend(KunMessage message) {
//        OperationProgressController operationProgressController = StageSingletonFactory.getInstance(OperationProgressController.class);
//        operationProgressController.put((String) message.getMessage());
//        defaultProducer.asyncPublish(message);
//    }
//
//}
